package com.link.base.base.user.service;

import com.alibaba.fastjson.JSONObject;
import com.link.base.base.auth.model.Authclient;
import com.link.base.base.position.model.Position;
import com.link.base.base.user.dao.mybatis.mapper.UserExperienceMapper;
import com.link.base.base.user.model.JWT;
import com.link.base.base.user.model.User;
import com.link.base.base.user.model.UserExperience;
import com.link.core.basic.dao.mapper.BasicMapper;
import com.link.core.basic.interceptor.SecurityInterceptor;
import com.link.core.basic.service.BasicServiceException;
import com.link.core.basic.service.BasicServiceImpl;
import com.link.core.basic.service.KeyGenerateService;
import com.link.core.cllog.LCLogger;
import com.link.core.util.*;
import com.link.core.util.redisclient.LinkRedisClient;
import com.link.microservice.AuthClient;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.io.UnsupportedEncodingException;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Random;

/**
 * 快速体验
 *
 * @author ouyangzhenqiang
 * @date 2018/12/27
 */
@Service
public class UserExperienceServiceImpl extends BasicServiceImpl<UserExperience> implements UserExperienceService {

    private static final String WECHAT_ENTRANCE = "wechat";

    /**
     * 应用类别 - 营销助手
     */
    private static final String marketing = "marketing";
    /**
     * 应用类别 - 经销商平台
     */
    private static final String dms = "dms";
    /**
     * 每个会话每次发送验证码的时间间隔（秒）
     */
    private static final int SEND_TIME_INTERVAL = 60;
    /**
     * 每个手机号验证码有效期（秒）
     */
    private static final int VERIFICATION_CODE_TERM = 300;
    /**
     * 验证码保存的唯一性识别key值
     */
    private static final String VERIFICATION_CODE_KEY = "#VerificationCode#Experience";
    /**
     * 最新的体验账号序号对象
     */
    private static final String LAST_EXPERIENCE_LOGIN_NUM_KEY = "LastExperienceLoginNum";
    /**
     * 企业微信登录类型
     */
    private static final String QY_WEHCAT = "QY_WEHCAT";

    @Resource
    private UserExperienceMapper userExperienceMapper;
    @Resource
    private UserService userService;
    @Resource
    protected KeyGenerateService keyGenerateService;
    @Resource
    private Environment env;
    @Resource
    private AuthClient authClient;

    @Override
    public BasicMapper<UserExperience> getBasicMapper() {
        return userExperienceMapper;
    }

    @Override
    public String sendSMSCode(UserExperience record) throws Exception {
        Map<String, Object> result = new HashMap<String, Object>();
        LinkRedisClient jedis = null;
        try {
            jedis = RedisUtil.getJedis();
            // 控制1分钟内对于重复手机号不再发送短信验证码
            String phone = record.getMobilePhone();
            String redisKey = phone + VERIFICATION_CODE_KEY;
            String sendTimeInterval = jedis.hget(redisKey, "sendTimeInterval");
            if (StringUtils.isNotBlank(sendTimeInterval)) {
                Long tempTime = DateUtil.getCurrentLongTime();
                Integer num = 1000;
                if ((tempTime - Long.parseLong(sendTimeInterval)) / num < SEND_TIME_INTERVAL) {
                    throw new BasicServiceException("60s内不再重复发送验证码");
                }
            }
            // 生成一个6位验证码
            String vCode = genSMSCode(6);
            // 发送短信验证码
            LinkedHashMap<String, String> params = new LinkedHashMap<String, String>();
            params.put("no", vCode);
            String vCodeMsgTemplate = PropertyUtil.getCommonProperty(RedisConstants.key_vCodeMsgTemplate);
            result = SendSmsUtil.sendMsg2(phone, vCodeMsgTemplate, params, null);
            String suc = "success";
            if (!(boolean) result.get(suc)) {
                throw new BasicServiceException(String.valueOf(result.get("result")));
            }
            // 设置缓存信息
            jedis.hset(redisKey, "mobilePhone", phone);
            jedis.hset(redisKey, "vCode", vCode);
            jedis.hset(redisKey, "sendTimeInterval", String.valueOf(DateUtil.getCurrentLongTime()));
            jedis.expire(redisKey, VERIFICATION_CODE_TERM);
        } finally {
            RedisUtil.returnResource(jedis);
        }
        return String.valueOf(SEND_TIME_INTERVAL);
    }

    @Override
    public void checkSMSCode(UserExperience record) throws Exception {
        LinkRedisClient jedis = null;
        try {
            jedis = RedisUtil.getJedis();
            String mobilePhone = record.getMobilePhone();
            String smsCode = record.getSmsCode();
            String redisKey = mobilePhone + VERIFICATION_CODE_KEY;
            String redisCode = jedis.hget(redisKey, "vCode");
            if (StringUtils.isBlank(redisCode)) {
                throw new BasicServiceException("验证码已过期，请重新获取！");
            } else if (!redisCode.equals(smsCode)) {
                throw new BasicServiceException("验证码不匹配，请检查！");
            }
            // 清楚缓存redis记录
            jedis.del(redisKey);
        } finally {
            RedisUtil.returnResource(jedis);
        }
    }

    @Override
    @Transactional(rollbackFor = BasicServiceException.class)
    public User generateExperienceUser(User baseUser, UserExperience experience) throws Exception {
        LinkRedisClient jedis = null;
        try {
            jedis = RedisUtil.getJedis();
            Long newPositionId = keyGenerateService.keyGenerate();
            Long newUserId = keyGenerateService.keyGenerate();
            // 按顺序生成登录账号
            String appType = experience.getAppType();
            String lastExperienceLoginNum;
            String experienceLogin;
            if (marketing.equals(appType)) {
                lastExperienceLoginNum = jedis.hget(LAST_EXPERIENCE_LOGIN_NUM_KEY, "LastExperienceMarketingLoginNum");
                if (StringUtils.isBlank(lastExperienceLoginNum)) {
                    lastExperienceLoginNum = "1";
                }
                experienceLogin = "ME" + lastExperienceLoginNum;
                jedis.hset(LAST_EXPERIENCE_LOGIN_NUM_KEY, "LastExperienceMarketingLoginNum",
                    String.valueOf(Integer.parseInt(lastExperienceLoginNum) + 1));
            } else if (dms.equals(appType)) {
                lastExperienceLoginNum = jedis.hget(LAST_EXPERIENCE_LOGIN_NUM_KEY, "LastExperienceDMSLoginNum");
                if (StringUtils.isBlank(lastExperienceLoginNum)) {
                    lastExperienceLoginNum = "1";
                }
                experienceLogin = "DE" + lastExperienceLoginNum;
                jedis.hset(LAST_EXPERIENCE_LOGIN_NUM_KEY, "LastExperienceDMSLoginNum",
                    String.valueOf(Integer.parseInt(lastExperienceLoginNum) + 1));
            } else {
                throw new BasicServiceException("应用类型不匹配：" + appType);
            }
            // 查询职位信息
            experience.setPostnId(baseUser.getPostnId());
            experience.setLoginCorpId(baseUser.getCorpid());
            Position position = userExperienceMapper.queryPostnByPostnId(experience);
            if (position == null) {
                throw new BasicServiceException("未匹配到可用职位！");
            }
            // 创建职位
            position.setId(newPositionId);
            position.setUserId(newUserId);
            position.setPostnName(position.getPostnName() + lastExperienceLoginNum);
            position.interfaceCreateData(0L, 0L, baseUser.getCorpid());
            userExperienceMapper.experiencePositionInsertByInterface(position);
            // 创建用户
            jedis = RedisUtil.getJedis();
            baseUser.setId(newUserId);
            baseUser.setContactPhone(experience.getMobilePhone());
            baseUser.setEmail(experience.getMobilePhone() + "@qq.com");
            baseUser.setUsername(experienceLogin);
            baseUser.setFirstName(this.genUserName());
            baseUser.setPostnId(newPositionId);
            baseUser.interfaceCreateData(0L, 0L, baseUser.getCorpid());
            userExperienceMapper.experienceUserInsertByInterface(baseUser);
            baseUser = userService.queryByUserName(experienceLogin);
            // 记录体验信息
            experience.setId(keyGenerateService.keyGenerate());
            experience.setUserLogin(experienceLogin);
            userExperienceMapper.experienceInsertByInterface(experience);
        } finally {
            RedisUtil.returnResource(jedis);
        }
        return baseUser;
    }

    @Override
    public User checkExperienceUser(UserExperience record) throws Exception {
        UserExperience userExperience = userExperienceMapper.queryByMobilePhone(record);
        if (userExperience != null) {
            User user = userService.queryByUserName(userExperience.getUserLogin());
            if (user == null) {
                throw new BasicServiceException("未检测到用户信息！");
            }
            return user;
        }
        return null;
    }

    @Override
    public User getBaseExperienceUser(UserExperience record) throws Exception {
        LinkRedisClient jedis = null;
        try {
            jedis = RedisUtil.getJedis();
            String appType = record.getAppType();
            String experienceLogin;
            if (marketing.equals(appType)) {
                experienceLogin = jedis.hget("APPLICATION_PARM_108", "marketingExperienceLogin");
            } else if (dms.equals(appType)) {
                experienceLogin = jedis.hget("APPLICATION_PARM_108", "dmsExperienceLogin");
            } else {
                throw new BasicServiceException("应用类型不匹配：" + appType);
            }
            User user = userService.queryByUserName(experienceLogin);
            if (user == null) {
                throw new BasicServiceException("未检测到用户信息！");
            }
            return user;
        } finally {
            RedisUtil.returnResource(jedis);
        }
    }

    @Override
    public JWT getToken(User record, String scope) throws Exception {
        Authclient authclient = userService.getAuthclient(scope, "");
        String authHeader = userService.genAuthHeader(authclient);
        String param = "";
        Map<String, String> jsonO = new HashMap<>(16);
        jsonO.put("username", record.getUsername());
        jsonO.put("password", param);
        jsonO.put("scope", scope);
        jsonO.put("grant_type", "password");
        jsonO.put("thirdName", "admin");
        jsonO.put("thirdPasswd", "appThirdLogin");
        String retStr = authClient.getToken(authHeader, jsonO);
        JSONObject json = JSONObject.parseObject(retStr);
        return JSONObject.toJavaObject(json, JWT.class);

    }

    @Override
    public Map<String, Object> experienceLogin(UserExperience record) throws Exception {
        Map<String, Object> result = new HashMap<>();

        try {
            // 短信验证码校验
            this.checkSMSCode(record);
            // 判断手机号是否存在，存在则直接拉取用户，否则重新创建体验账号
            User experienceUser = this.checkExperienceUser(record);
            if (experienceUser == null) {
                // 获取系统中维护的体验账号基础匹配用户
                User baseUser = this.getBaseExperienceUser(record);
                // 基于基础匹配账号创建体验用户
                experienceUser = this.generateExperienceUser(baseUser, record);
            }
            // 免密登录获取token及设置相关信息
            UserExperience userExperience = this.loginWithOutPassword(experienceUser);
            // 返回数据
            result.put("success", true);
            result.put("token", userExperience.getToken());
            result.put("result", userExperience.getUser());
        } catch (Exception e) {
            LCLogger.withException(e);
            LCLogger.error().withMessageKey("experienceLogin")
                .withMessage("快速体验登录失败：" + e.getMessage()).flush();
            result.put("success", false);
            result.put("result", e.getMessage());
        }
        return result;
    }

    @Override
    public UserExperience loginWithOutPassword(User record) throws Exception {
        UserExperience userExperience = new UserExperience();
        LinkRedisClient jedis = null;
        try {
            // 免密码登录，获取token
            jedis = RedisUtil.getJedis();
            JWT jwt = this.getToken(record, WECHAT_ENTRANCE);
            String token = jwt.getAccess_token();
            int tokenExpire = jwt.getExpires_in();
            // 认证成功后将登录用户信息存到redis
            SecurityInterceptor.token.set(token);
            // 把用户放到线程里面，保证下面的操作，是基于当前登录用户
            if (StringUtils.isNull(record.getCurClientId())) {
                record.setCurClientId(WECHAT_ENTRANCE);
            }
            // 根据当前用户设置登录类型

            record.setLoginType(QY_WEHCAT);
            SecurityInterceptor.tempUser.set(record);
            userService.setLoginInfo(token, record, "", tokenExpire, WECHAT_ENTRANCE, null);
            String userJsonStr = JSONObject.toJSONString(record);
            jedis.set(token, userJsonStr);
            jedis.expire(token, tokenExpire);
            userExperience.setUser(record);
            userExperience.setToken(token);
        } finally {
            RedisUtil.returnResource(jedis);
        }
        return userExperience;
    }

    @Override
    public String genUserName() throws Exception {
        Random random = new Random(System.currentTimeMillis());
        String[] Surname = {"赵","钱","孙","李","周","吴","郑","王","冯","陈","褚","卫","蒋","沈","韩","杨","朱","秦","尤","许",
            "何","吕","施","张","孔","曹","严","华","金","魏","陶","姜","戚","谢","邹","喻","柏","水","窦","章","云","苏","潘","葛","奚","范","彭","郎",
            "鲁","韦","昌","马","苗","凤","花","方","俞","任","袁","柳","酆","鲍","史","唐","费","廉","岑","薛","雷","贺","倪","汤","滕","殷",
            "罗","毕","郝","邬","安","常","乐","于","时","傅","皮","卞","齐","康","伍","余","元","卜","顾","孟","平","黄","和",
            "穆","萧","尹","姚","邵","湛","汪","祁","毛","禹","狄","米","贝","明","臧","计","伏","成","戴","谈","宋","茅","庞","熊","纪","舒",
            "屈","项","祝","董","梁","杜","阮","蓝","闵","席","季","麻","强","贾","路","娄","危","江","童","颜","郭","梅","盛","林","刁","钟",
            "徐","邱","骆","高","夏","蔡","田","樊","胡","凌","霍","虞","万","支","柯","昝","管","卢","莫","经","房","裘","缪","干","解","应",
            "宗","丁","宣","贲","邓","郁","单","杭","洪","包","诸","左","石","崔","吉","钮","龚","程","嵇","邢","滑","裴","陆","荣","翁","荀",
            "羊","于","惠","甄","曲","家","封","芮","羿","储","靳","汲","邴","糜","松","井","段","富","巫","乌","焦","巴","弓","牧","隗","山",
            "谷","车","侯","宓","蓬","全","郗","班","仰","秋","仲","伊","宫","宁","仇","栾","暴","甘","钭","厉","戎","祖","武","符","刘","景",
            "詹","束","龙","叶","幸","司","韶","郜","黎","蓟","溥","印","宿","白","怀","蒲","邰","从","鄂","索","咸","籍","赖","卓","蔺","屠",
            "蒙","池","乔","阴","郁","胥","能","苍","双","闻","莘","党","翟","谭","贡","劳","逄","姬","申","扶","堵","冉","宰","郦","雍","却",
            "璩","桑","桂","濮","牛","寿","通","边","扈","燕","冀","浦","尚","农","温","别","庄","晏","柴","瞿","阎","充","慕","连","茹","习",
            "宦","艾","鱼","容","向","古","易","慎","戈","廖","庾","终","暨","居","衡","步","都","耿","满","弘","匡","国","文","寇","广","禄",
            "阙","东","欧","殳","沃","利","蔚","越","夔","隆","师","巩","厍","聂","晁","勾","敖","融","冷","訾","辛","阚","那","简","饶","空",
            "曾","毋","沙","乜","养","鞠","须","丰","巢","关","蒯","相","查","后","荆","红","游","郏","竺","权","逯","盖","益","桓","公","仉",
            "督","岳","帅","缑","亢","况","郈","有","琴","归","海","晋","楚","闫","法","汝","鄢","涂","钦","商","牟","佘","佴","伯","赏","墨",
            "哈","谯","篁","年","爱","阳","佟","言","福","南","火","铁","迟","漆","官","冼","真","展","繁","檀","祭","密","敬","揭","舜","楼",
            "疏","冒","浑","挚","胶","随","高","皋","原","种","练","弥","仓","眭","蹇","覃","阿","门","恽","来","綦","召","仪","风","介","巨",
            "木","京","狐","郇","虎","枚","抗","达","杞","苌","折","麦","庆","过","竹","端","鲜","皇","亓","老","是","秘","畅","邝","还","宾",
            "闾","辜","纵","侴","万俟","司马","上官","欧阳","夏侯","诸葛","闻人","东方","赫连","皇甫","羊舌","尉迟","公羊","澹台","公冶","宗正",
            "濮阳","淳于","单于","太叔","申屠","公孙","仲孙","轩辕","令狐","钟离","宇文","长孙","慕容","鲜于","闾丘","司徒","司空","兀官","司寇",
            "南门","呼延","子车","颛孙","端木","巫马","公西","漆雕","车正","壤驷","公良","拓跋","夹谷","宰父","谷梁","段干","百里","东郭","微生",
            "梁丘","左丘","东门","西门","南宫","第五","公仪","公乘","太史","仲长","叔孙","屈突","尔朱","东乡","相里","胡母","司城","张廖","雍门",
            "毋丘","贺兰","綦毋","屋庐","独孤","南郭","北宫","王孙"};
        return Surname[random.nextInt(Surname.length - 1)] + this.getChinese() + this.getChinese();
    }

    @Override
    public String getChinese() throws Exception {
        String str = "";
        int highPos;
        int lowPos;
        Random random = new Random();
        // 区码，0xA0打头，从第16区开始，即0xB0=11*16=176,16~55一级汉字，56~87二级汉字
        highPos = (176 + Math.abs(random.nextInt(71)));
        random = new Random();
        // 位码，0xA0打头，范围第1~94列
        lowPos = 161 + Math.abs(random.nextInt(94));
        byte[] bArr = new byte[2];
        bArr[0] = (new Integer(highPos)).byteValue();
        bArr[1] = (new Integer(lowPos)).byteValue();
        try {
            // 区位码组合成汉字
            str = new String(bArr, "GB2312");
        } catch (UnsupportedEncodingException e) {
            LCLogger.withException(e);
        }
        return str;
    }

    @Override
    public String genSMSCode(int num) throws Exception {
        Random rd = new Random();
        String code = "";
        for (int i = 0; i < num; i++) {
            code += String.valueOf(rd.nextInt(10));
        }
        return code;
    }
}

